package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * @author: zigui.zdf
 * @description:
 * @date: 2021/7/22 15:06
 */
@Data
//@ApiModel
public class RestartJobDomain {

    //    @ApiModelProperty(value = "记录id", required = true)
    @NotNull(message = "记录id不能为空")
    private Long id;

    //    @ApiModelProperty(
//        value = "重跑类型，0-丢弃停止前的状态 1-使用上次任务参数重跑 2-指定offset",
//        required = true,
//        allowableValues = "0,1,2")
    @NotNull(message = "重跑类型不能为空")
    private Integer type;

    //    @ApiModelProperty(value = "offset，type为2时传入")
    private List<TableTime> tableTimes;

    @Data
//    @ApiModel
    public static class TableTime {
        //    @ApiModelProperty(value = "表名")
        private String table;

        //    @ApiModelProperty(value = "时间戳,yyyy-MM-dd HH:mm:ss")
        private String time;
    }
}
